package com.sjk.flink.pojo;

import lombok.Data;

/**
 * kafka消息来源
 *
 * @author SAMA
 */
@Data
public class ODS1 {

    /** 城市消息 **/
    private String record;

    /** 城市代码 **/
    private String sscsdm;

    /** 执行时间 **/
    private String extract_time;

    private String kssj;

    private String topic;


}
